對於kafka的consumer接口，提供兩種版本， high-level 一種high-level版本，比較簡單不用關心offset, 會自動的讀zookeeper中該Consumer g ...

listeners, Listener List - Comma-separated list of URIs we will listen on and their protocols. Spec ...

Kafka 作為 high throughput 的消息中間件，以其性能，簡單和穩定性，成為當前實時流處理框架中的主流的基礎組件。 當然在使用 Kafka 中也碰到不少問題，尤其是 failover ...

參考， https://cwiki.apache.org/confluence/display/KAFKA/System+Tools https://cwiki.apache.org/conflu ...

2.1 Producer API We encourage all new development to use the new Java producer. This client is prod ...

pollOnce 看下fetcher 創建時， 可以看出對應的配置 fetcher.fetchedRecord ...

Metrics-Java版的指標度量工具之一 Metrics-Java版的指標度量工具之二 JAVA Metrics 度量工具使用介紹1 JAVA Metrics度量工具 - Metrics ...

參考， https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example http://kafka.apache.o ...

首先kafka的throughput 很牛逼，參考：http://engineering.linkedin.com/kafka/benchmarking-apache-kafka-2-million- ...

https://github.com/wurstmeister/storm-kafka-0.8-plus http://blog.csdn.net/xeseo/article/details/186 ...